//package com.ruoyi.web.controller.kafka;
//
//import com.ruoyi.common.core.domain.AjaxResult;
//import com.ruoyi.common.utils.uuid.UUID;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import javax.annotation.Resource;
//
//@RestController
//@RequestMapping("/test")
//public class KafkaController {
//
//    private static final String TOPIC = "zhstest11";
//
//    @Resource
//    private KafkaTemplate<String,Object> kafkaTemplate;
//
//    //发送数据
//    @GetMapping("/send")
//    public AjaxResult sendMessage() {
//        String uuid = UUID.randomUUID().toString();
//        kafkaTemplate.send(TOPIC, "hello kafka" + uuid);
//        return AjaxResult.success("数据发送成功");
//    }
//}
